package com.wuad.platformwuad.util;

import org.springframework.beans.factory.annotation.Value;

import lombok.extern.slf4j.Slf4j;
import java.sql.*;
/**
 * 存储过程调用
 *
 *
 */
@Slf4j
public class CunchuUtils {

    /**
     * 数据库链接地址
     */
    @Value("${spring.datasource.url}")
    private String dataSourceUrl;
    /**
     * 数据库链接用户名
     */
    @Value("${spring.datasource.username}")
    private String dataSourceUserName;
    /**
     * 数据库链接密码
     */
    @Value("${spring.datasource.password}")
    private String dataSourcePassword;


    /**
     * 调用存储过程
     */
    public void diaoyong() {
        try {
            // 连接数据库
            Connection conn = DriverManager.getConnection(dataSourceUrl, dataSourceUserName, dataSourcePassword);
            // 调用存储过程
            CallableStatement cstmt = conn.prepareCall("call PRO_AWDM_T_PEWARN_MESSAGE('20230922')");
//                                    cstmt.setString(1, "param1");
//                                    cstmt.setInt(2, 2);
            // 执行存储过程
            boolean hasResults = cstmt.execute();
            // 检查结果
            if (!hasResults && cstmt.getUpdateCount() == -1) {
                log.info("=====================存储过程执行完毕========================");
            } else {
                // 处理结果集
                ResultSet rs = cstmt.getResultSet();
                while (rs.next()) {
                    // 处理每一行结果
                }
            }
            // 关闭连接
            conn.close();
        } catch (SQLException e) {
            log.info("===============存储过程执行执行异常：{}===================", e);
        }
    }
}
